* This does not really buy anything for a number of reason and
can cause bugs. For example, if the aggregator is notified due
to undelayed jobs but this cache is not updated, then the runners
will not see the jobs and will de-list aggregator entry.
bug: 68506
Change-Id: I1eacca108df59fff9c0fcc846aafaf1616cf5895
}
protected function doPop() {
- $key = $this->getCacheKey( 'empty' );
-
- $isEmpty = $this->cache->get( $key );
- if ( $isEmpty === 'true' ) {
- return false;
- }
-
$partitionsTry = $this->partitionRing->getLiveLocationWeights(); // (partition => weight)
$failed = 0;
}
$this->throwErrorIfAllPartitionsDown( $failed );
+ $key = $this->getCacheKey( 'empty' );
$this->cache->set( $key, 'true', JobQueueDB::CACHE_TTL_LONG );
return false;